﻿using Newtonsoft.Json.Serialization;
using QbservableCore.Serialization;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reactive.Linq;
using System.Text;
using System.Threading.Tasks;

namespace QbservableHubTests
{
    public class TestTargetResolver : IQbservableTargetResolver
    {
        public IQbservable ToQbservable(string targetKey)
        {
            IQbservable retQbservable = null;
            switch(targetKey)
            {
                case "F1":
                    var obs = Observable.Range(0, 10);
                    retQbservable = obs.AsQbservable();
                    break;
            }

            return retQbservable;
        }

        public QbservableMetadata[] GetMetadata()
        {
            throw new NotImplementedException();
        }
    }
}
